package kafka

//
//type BaseKafkaModel struct {
//}
//
//func (b *BaseKafkaModel) GetKafkaProducerClient() (*kafkaPool, error) {
//	pool := NewKafkaPool()
//	err := pool.Init()
//	if err != nil {
//		return nil, err
//	}
//	return pool, nil
//}
//
//func (b *BaseKafkaModel) GetKafkaConsumerClient() (*kafkaPool, error) {
//	pool := NewKafkaPool()
//	err := pool.Init()
//	if err != nil {
//		return nil, err
//	}
//	return pool, nil
//}
